🎖️GitЯра🎖️
Node / meshtastic / Meshtastic-Android / files / core / data / src / commonTest / kotlin / org / meshtastic / core / data / manager / NodeManagerConnectionIdentityTest.kt
Displaying Raw • Download
core/data/src/commonTest/kotlin/org/meshtastic/core/data/manager/NodeManagerConnectionIdentityTest.kt 01cd54907d62cd90913d3d071b6bc240cae365ef (01cd5490) Text, 10.63 KB
T8b949e/*
* Copyright (c) 2026 Meshtastic LLC
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
Tff7b72package T7ee787org.meshtastic.core.data.manager
Tff7b72import T7ee787dev.mokkery.MockMode
Tff7b72import T7ee787dev.mokkery.answering.returns
Tff7b72import T7ee787dev.mokkery.every
Tff7b72import T7ee787dev.mokkery.everySuspend
Tff7b72import T7ee787dev.mokkery.mock
Tff7b72import T7ee787kotlinx.coroutines.flow.MutableStateFlow
Tff7b72import T7ee787kotlinx.coroutines.launch
Tff7b72import T7ee787kotlinx.coroutines.test.TestScope
Tff7b72import T7ee787kotlinx.coroutines.test.runCurrent
Tff7b72import T7ee787kotlinx.coroutines.test.runTest
Tff7b72import T7ee787org.meshtastic.core.model.MyNodeInfo
Tff7b72import T7ee787org.meshtastic.core.repository.ConnectionIdentity
Tff7b72import T7ee787org.meshtastic.core.repository.NodeRepository
Tff7b72import T7ee787org.meshtastic.core.repository.NotificationManager
Tff7b72import T7ee787org.meshtastic.core.repository.RadioInterfaceService
Tff7b72import T7ee787kotlin.test.BeforeTest
Tff7b72import T7ee787kotlin.test.Test
Tff7b72import T7ee787kotlin.test.assertEquals
Tff7b72import T7ee787kotlin.test.assertFalse
Tff7b72import T7ee787kotlin.test.assertNotEquals
Tff7b72import T7ee787kotlin.test.assertNull
Tff7b72import T7ee787kotlin.test.assertTrue
T8b949e/**
* Verifies [NodeManagerImpl.connectionIdentity] — the fresh-handshake identity source that stays separate from the
* general [NodeManagerImpl.myNodeNum]/[NodeManagerImpl.myDeviceId] StateFlows so a stale cached identity cannot
* associate a new transport address with a previous device. Covers publish/clear semantics, loadCachedNodeDB
* non-population, full-reset behavior, StateFlow distinctness, null-deviceId handling, and address binding.
*/
Tff7b72class T56d364NodeManagerConnectionIdentityTest Tb4b4b4{
Tff7b72private Tff7b72val Te6edf3nodeRepositoryTb4b4b4: Te6edf3NodeRepository Tff7b72= Te6edf3mockTb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3notificationManagerTb4b4b4: Te6edf3NotificationManager Tff7b72= Te6edf3mockTb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3radioInterfaceServiceTb4b4b4: Te6edf3RadioInterfaceService Tff7b72= Te6edf3mockTb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3testScope Tff7b72= Te6edf3TestScopeTb4b4b4(Tb4b4b4)
Tff7b72private Tff7b72lateinit Tff7b72var Te6edf3nodeManagerTb4b4b4: Te6edf3NodeManagerImpl
Tf0883e@BeforeTest
Tff7b72fun Td2a8ffsetUpTb4b4b4(Tb4b4b4) Tb4b4b4{
Te6edf3everySuspend Tb4b4b4{ Te6edf3nodeRepositoryTb4b4b4.Te6edf3getNodeDbSnapshotTb4b4b4(Tb4b4b4) Tb4b4b4} Te6edf3returns Te6edf3emptyMapTb4b4b4(Tb4b4b4)
Te6edf3nodeManager Tff7b72= Te6edf3NodeManagerImplTb4b4b4(Te6edf3nodeRepositoryTb4b4b4, Te6edf3notificationManagerTb4b4b4, Te6edf3radioInterfaceServiceTb4b4b4, Te6edf3testScopeTb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`publish then clear sets and nulls connectionIdentity`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3assertNullTb4b4b4(Te6edf3nodeManagerTb4b4b4.Te6edf3connectionIdentityTb4b4b4.Te6edf3valueTb4b4b4, Ta5d6ff"Ta5d6ffidentity should start nullTa5d6ff"Tb4b4b4)
Te6edf3nodeManagerTb4b4b4.Te6edf3publishConnectionIdentityTb4b4b4(
Te6edf3sessionGeneration Tff7b72= T79c0ff1LTb4b4b4,
Te6edf3address Tff7b72= Ta5d6ff"Ta5d6fftcp:oneTa5d6ff"Tb4b4b4,
Te6edf3nodeNum Tff7b72= T79c0ff4T79c0ff2Tb4b4b4,
Te6edf3deviceId Tff7b72= Ta5d6ff"Ta5d6ffdeadbeefTa5d6ff"Tb4b4b4,
Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(
Te6edf3ConnectionIdentityTb4b4b4(Te6edf3sessionGeneration Tff7b72= T79c0ff1LTb4b4b4, Te6edf3address Tff7b72= Ta5d6ff"Ta5d6fftcp:oneTa5d6ff"Tb4b4b4, Te6edf3nodeNum Tff7b72= T79c0ff4T79c0ff2Tb4b4b4, Te6edf3deviceId Tff7b72= Ta5d6ff"Ta5d6ffdeadbeefTa5d6ff"Tb4b4b4)Tb4b4b4,
Te6edf3nodeManagerTb4b4b4.Te6edf3connectionIdentityTb4b4b4.Te6edf3valueTb4b4b4,
Tb4b4b4)
Te6edf3nodeManagerTb4b4b4.Te6edf3clearConnectionIdentityTb4b4b4(Tb4b4b4)
Te6edf3assertNullTb4b4b4(Te6edf3nodeManagerTb4b4b4.Te6edf3connectionIdentityTb4b4b4.Te6edf3valueTb4b4b4, Ta5d6ff"Ta5d6ffidentity should be null after clearTa5d6ff"Tb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`connectionIdentity diagnostic text redacts persistent identifiers`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3identity Tff7b72= Te6edf3ConnectionIdentityTb4b4b4(T79c0ff7LTb4b4b4, Ta5d6ff"Ta5d6ffble:AA:BB:CC:DD:EE:FFTa5d6ff"Tb4b4b4, T79c0ff4T79c0ff2Tb4b4b4, Ta5d6ff"Ta5d6fffactory-burned-idTa5d6ff"Tb4b4b4)
Tff7b72val Te6edf3diagnostic Tff7b72= Te6edf3identityTb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)
Te6edf3assertFalseTb4b4b4(Ta5d6ff"Ta5d6ffAA:BB:CC:DD:EE:FFTa5d6ff" Tff7b72in Te6edf3diagnosticTb4b4b4)
Te6edf3assertFalseTb4b4b4(Ta5d6ff"Ta5d6fffactory-burned-idTa5d6ff" Tff7b72in Te6edf3diagnosticTb4b4b4)
Te6edf3assertTrueTb4b4b4(Ta5d6ff"Ta5d6ffsessionGeneration=7Ta5d6ff" Tff7b72in Te6edf3diagnosticTb4b4b4)
Te6edf3assertTrueTb4b4b4(Ta5d6ff"Ta5d6ffnodeNum=42Ta5d6ff" Tff7b72in Te6edf3diagnosticTb4b4b4)
Te6edf3assertTrueTb4b4b4(Ta5d6ff"Ta5d6ffdeviceIdPresent=trueTa5d6ff" Tff7b72in Te6edf3diagnosticTb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`generation-aware clear preserves fresh identity and removes stale identity`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3freshIdentity Tff7b72= Te6edf3ConnectionIdentityTb4b4b4(T79c0ff2LTb4b4b4, Ta5d6ff"Ta5d6fftcp:oneTa5d6ff"Tb4b4b4, T79c0ff4T79c0ff2Tb4b4b4, Ta5d6ff"Ta5d6ffdeadbeefTa5d6ff"Tb4b4b4)
Te6edf3nodeManagerTb4b4b4.Te6edf3publishConnectionIdentityTb4b4b4(
Te6edf3sessionGeneration Tff7b72= Te6edf3freshIdentityTb4b4b4.Te6edf3sessionGenerationTb4b4b4,
Te6edf3address Tff7b72= Te6edf3freshIdentityTb4b4b4.Te6edf3addressTb4b4b4,
Te6edf3nodeNum Tff7b72= Te6edf3freshIdentityTb4b4b4.Te6edf3nodeNumTb4b4b4,
Te6edf3deviceId Tff7b72= Te6edf3freshIdentityTb4b4b4.Te6edf3deviceIdTb4b4b4,
Tb4b4b4)
Te6edf3nodeManagerTb4b4b4.Te6edf3clearStaleConnectionIdentityTb4b4b4(Te6edf3activeSessionGeneration Tff7b72= T79c0ff2LTb4b4b4)
Te6edf3assertEqualsTb4b4b4(Te6edf3freshIdentityTb4b4b4, Te6edf3nodeManagerTb4b4b4.Te6edf3connectionIdentityTb4b4b4.Te6edf3valueTb4b4b4, Ta5d6ff"Ta5d6ffthe active generation must be preservedTa5d6ff"Tb4b4b4)
Te6edf3nodeManagerTb4b4b4.Te6edf3clearStaleConnectionIdentityTb4b4b4(Te6edf3activeSessionGeneration Tff7b72= T79c0ff3LTb4b4b4)
Te6edf3assertNullTb4b4b4(Te6edf3nodeManagerTb4b4b4.Te6edf3connectionIdentityTb4b4b4.Te6edf3valueTb4b4b4, Ta5d6ff"Ta5d6ffan identity from the prior generation must be clearedTa5d6ff"Tb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`loadCachedNodeDB does not populate connectionIdentity`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
T8b949e// Even with a non-null myNodeInfo in the repo cache, connectionIdentity must remain null — only a fresh
T8b949e// MyNodeInfo handshake publishes the identity (see publishConnectionIdentity).
Te6edf3every Tb4b4b4{ Te6edf3nodeRepositoryTb4b4b4.Te6edf3nodeDBbyNum Tb4b4b4} Te6edf3returns Te6edf3MutableStateFlowTb4b4b4(Te6edf3emptyMapTb4b4b4(Tb4b4b4)Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3nodeRepositoryTb4b4b4.Te6edf3myNodeInfo Tb4b4b4} Te6edf3returns Te6edf3MutableStateFlowTb4b4b4(Te6edf3cachedMyNodeInfoTb4b4b4(Te6edf3myNodeNum Tff7b72= T79c0ff7T79c0ff7T79c0ff7Tb4b4b4)Tb4b4b4)
Te6edf3nodeManagerTb4b4b4.Te6edf3loadCachedNodeDBTb4b4b4(Tb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
T8b949e// myNodeNum may have been restored from cache, but connectionIdentity must NOT.
Te6edf3assertEqualsTb4b4b4(T79c0ff7T79c0ff7T79c0ff7Tb4b4b4, Te6edf3nodeManagerTb4b4b4.Te6edf3myNodeNumTb4b4b4.Te6edf3valueTb4b4b4, Ta5d6ff"Ta5d6ffmyNodeNum should be restored from cacheTa5d6ff"Tb4b4b4)
Te6edf3assertNullTb4b4b4(Te6edf3nodeManagerTb4b4b4.Te6edf3connectionIdentityTb4b4b4.Te6edf3valueTb4b4b4, Ta5d6ff"Ta5d6ffconnectionIdentity must not be populated by cache reloadTa5d6ff"Tb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`clear resets connectionIdentity alongside other state`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3nodeManagerTb4b4b4.Te6edf3publishConnectionIdentityTb4b4b4(
Te6edf3sessionGeneration Tff7b72= T79c0ff1LTb4b4b4,
Te6edf3address Tff7b72= Ta5d6ff"Ta5d6fftcp:oneTa5d6ff"Tb4b4b4,
Te6edf3nodeNum Tff7b72= T79c0ff4T79c0ff2Tb4b4b4,
Te6edf3deviceId Tff7b72= Ta5d6ff"Ta5d6ffdeadbeefTa5d6ff"Tb4b4b4,
Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(Te6edf3ConnectionIdentityTb4b4b4(T79c0ff1LTb4b4b4, Ta5d6ff"Ta5d6fftcp:oneTa5d6ff"Tb4b4b4, T79c0ff4T79c0ff2Tb4b4b4, Ta5d6ff"Ta5d6ffdeadbeefTa5d6ff"Tb4b4b4)Tb4b4b4, Te6edf3nodeManagerTb4b4b4.Te6edf3connectionIdentityTb4b4b4.Te6edf3valueTb4b4b4)
Te6edf3nodeManagerTb4b4b4.Te6edf3clearTb4b4b4(Tb4b4b4)
Te6edf3assertNullTb4b4b4(Te6edf3nodeManagerTb4b4b4.Te6edf3connectionIdentityTb4b4b4.Te6edf3valueTb4b4b4, Ta5d6ff"Ta5d6ffclear() must reset connectionIdentityTa5d6ff"Tb4b4b4)
Te6edf3assertNullTb4b4b4(Te6edf3nodeManagerTb4b4b4.Te6edf3myNodeNumTb4b4b4.Te6edf3valueTb4b4b4, Ta5d6ff"Ta5d6ffclear() must reset myNodeNumTa5d6ff"Tb4b4b4)
Te6edf3assertNullTb4b4b4(Te6edf3nodeManagerTb4b4b4.Te6edf3myDeviceIdTb4b4b4.Te6edf3valueTb4b4b4, Ta5d6ff"Ta5d6ffclear() must reset myDeviceIdTa5d6ff"Tb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`connectionIdentity StateFlow emits only distinct values`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3emissions Tff7b72= Te6edf3mutableListOfTff7b72<Te6edf3ConnectionIdentity?Tff7b72>Tb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3collector Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3launch Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3connectionIdentityTb4b4b4.Te6edf3collect Tb4b4b4{ Te6edf3emissions Tff7b72+Tff7b72= Tffa657it Tb4b4b4} Tb4b4b4}
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
T8b949e// Initial replay: the starting null value.
Te6edf3assertEqualsTb4b4b4(
Te6edf3listOfTff7b72<Te6edf3ConnectionIdentity?Tff7b72>Tb4b4b4(Tff7b72nullTb4b4b4)Tb4b4b4,
Te6edf3emissionsTb4b4b4,
Ta5d6ff"Ta5d6ffonly the initial null should be present before any publishTa5d6ff"Tb4b4b4,
Tb4b4b4)
T8b949e// First publish — produces one new emission.
Te6edf3nodeManagerTb4b4b4.Te6edf3publishConnectionIdentityTb4b4b4(
Te6edf3sessionGeneration Tff7b72= T79c0ff1LTb4b4b4,
Te6edf3address Tff7b72= Ta5d6ff"Ta5d6fftcp:oneTa5d6ff"Tb4b4b4,
Te6edf3nodeNum Tff7b72= T79c0ff4T79c0ff2Tb4b4b4,
Te6edf3deviceId Tff7b72= Ta5d6ff"Ta5d6ffdeadbeefTa5d6ff"Tb4b4b4,
Tb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(
Te6edf3listOfTb4b4b4(Tff7b72nullTb4b4b4, Te6edf3ConnectionIdentityTb4b4b4(T79c0ff1LTb4b4b4, Ta5d6ff"Ta5d6fftcp:oneTa5d6ff"Tb4b4b4, T79c0ff4T79c0ff2Tb4b4b4, Ta5d6ff"Ta5d6ffdeadbeefTa5d6ff"Tb4b4b4)Tb4b4b4)Tb4b4b4,
Te6edf3emissionsTb4b4b4,
Ta5d6ff"Ta5d6fffirst publish should emit onceTa5d6ff"Tb4b4b4,
Tb4b4b4)
T8b949e// Re-publishing an equal value must NOT emit again — StateFlow conflates equal values, so any downstream
T8b949e// distinctUntilChanged (e.g. RadioControllerImpl's combine collector) skips it.
Te6edf3nodeManagerTb4b4b4.Te6edf3publishConnectionIdentityTb4b4b4(
Te6edf3sessionGeneration Tff7b72= T79c0ff1LTb4b4b4,
Te6edf3address Tff7b72= Ta5d6ff"Ta5d6fftcp:oneTa5d6ff"Tb4b4b4,
Te6edf3nodeNum Tff7b72= T79c0ff4T79c0ff2Tb4b4b4,
Te6edf3deviceId Tff7b72= Ta5d6ff"Ta5d6ffdeadbeefTa5d6ff"Tb4b4b4,
Tb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(
Te6edf3listOfTb4b4b4(Tff7b72nullTb4b4b4, Te6edf3ConnectionIdentityTb4b4b4(T79c0ff1LTb4b4b4, Ta5d6ff"Ta5d6fftcp:oneTa5d6ff"Tb4b4b4, T79c0ff4T79c0ff2Tb4b4b4, Ta5d6ff"Ta5d6ffdeadbeefTa5d6ff"Tb4b4b4)Tb4b4b4)Tb4b4b4,
Te6edf3emissionsTb4b4b4,
Ta5d6ff"Ta5d6ffequal re-publication must not re-emitTa5d6ff"Tb4b4b4,
Tb4b4b4)
T8b949e// A genuinely different value does emit.
Te6edf3nodeManagerTb4b4b4.Te6edf3publishConnectionIdentityTb4b4b4(
Te6edf3sessionGeneration Tff7b72= T79c0ff1LTb4b4b4,
Te6edf3address Tff7b72= Ta5d6ff"Ta5d6fftcp:twoTa5d6ff"Tb4b4b4,
Te6edf3nodeNum Tff7b72= T79c0ff4T79c0ff3Tb4b4b4,
Te6edf3deviceId Tff7b72= Ta5d6ff"Ta5d6ffdeadbeefTa5d6ff"Tb4b4b4,
Tb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(
Te6edf3listOfTb4b4b4(
Tff7b72nullTb4b4b4,
Te6edf3ConnectionIdentityTb4b4b4(T79c0ff1LTb4b4b4, Ta5d6ff"Ta5d6fftcp:oneTa5d6ff"Tb4b4b4, T79c0ff4T79c0ff2Tb4b4b4, Ta5d6ff"Ta5d6ffdeadbeefTa5d6ff"Tb4b4b4)Tb4b4b4,
Te6edf3ConnectionIdentityTb4b4b4(T79c0ff1LTb4b4b4, Ta5d6ff"Ta5d6fftcp:twoTa5d6ff"Tb4b4b4, T79c0ff4T79c0ff3Tb4b4b4, Ta5d6ff"Ta5d6ffdeadbeefTa5d6ff"Tb4b4b4)Tb4b4b4,
Tb4b4b4)Tb4b4b4,
Te6edf3emissionsTb4b4b4,
Ta5d6ff"Ta5d6ffdifferent value must emitTa5d6ff"Tb4b4b4,
Tb4b4b4)
Te6edf3collectorTb4b4b4.Te6edf3cancelTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`publish with null deviceId keeps address and nodeNum set`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3nodeManagerTb4b4b4.Te6edf3publishConnectionIdentityTb4b4b4(
Te6edf3sessionGeneration Tff7b72= T79c0ff1LTb4b4b4,
Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ffble:oneTa5d6ff"Tb4b4b4,
Te6edf3nodeNum Tff7b72= T79c0ff9T79c0ff9Tb4b4b4,
Te6edf3deviceId Tff7b72= Tff7b72nullTb4b4b4,
Tb4b4b4)
Tff7b72val Te6edf3identity Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3connectionIdentityTb4b4b4.Te6edf3value
Te6edf3assertNotEqualsTb4b4b4(Tff7b72nullTb4b4b4, Te6edf3identityTb4b4b4, Ta5d6ff"Ta5d6ffidentity itself must not be nullTa5d6ff"Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ffble:oneTa5d6ff"Tb4b4b4, Te6edf3identityTff7b72?.Te6edf3addressTb4b4b4, Ta5d6ff"Ta5d6ffaddress must identify the handshake transportTa5d6ff"Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(T79c0ff9T79c0ff9Tb4b4b4, Te6edf3identityTff7b72?.Te6edf3nodeNumTb4b4b4, Ta5d6ff"Ta5d6ffnodeNum must be set even when deviceId is nullTa5d6ff"Tb4b4b4)
Te6edf3assertNullTb4b4b4(Te6edf3identityTff7b72?.Te6edf3deviceIdTb4b4b4, Ta5d6ff"Ta5d6ffdeviceId must remain nullTa5d6ff"Tb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`clearing a session removes its address-bound identity`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
T8b949e// Simulate the previous transport publishing its handshake identity.
Te6edf3nodeManagerTb4b4b4.Te6edf3publishConnectionIdentityTb4b4b4(
Te6edf3sessionGeneration Tff7b72= T79c0ff1LTb4b4b4,
Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ffble:oldTa5d6ff"Tb4b4b4,
Te6edf3nodeNum Tff7b72= T79c0ff4T79c0ff2Tb4b4b4,
Te6edf3deviceId Tff7b72= Ta5d6ff"Ta5d6ffdeadbeefTa5d6ff"Tb4b4b4,
Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(Te6edf3ConnectionIdentityTb4b4b4(T79c0ff1LTb4b4b4, Ta5d6ff"Ta5d6ffble:oldTa5d6ff"Tb4b4b4, T79c0ff4T79c0ff2Tb4b4b4, Ta5d6ff"Ta5d6ffdeadbeefTa5d6ff"Tb4b4b4)Tb4b4b4, Te6edf3nodeManagerTb4b4b4.Te6edf3connectionIdentityTb4b4b4.Te6edf3valueTb4b4b4)
Te6edf3nodeManagerTb4b4b4.Te6edf3clearConnectionIdentityTb4b4b4(Tb4b4b4)
Te6edf3assertNullTb4b4b4(Te6edf3nodeManagerTb4b4b4.Te6edf3connectionIdentityTb4b4b4.Te6edf3valueTb4b4b4, Ta5d6ff"Ta5d6ffidentity must be null after the session is clearedTa5d6ff"Tb4b4b4)
T8b949e// Even after subsequent loadCachedNodeDB-style state restoration, identity stays null.
Te6edf3every Tb4b4b4{ Te6edf3nodeRepositoryTb4b4b4.Te6edf3nodeDBbyNum Tb4b4b4} Te6edf3returns Te6edf3MutableStateFlowTb4b4b4(Te6edf3emptyMapTb4b4b4(Tb4b4b4)Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3nodeRepositoryTb4b4b4.Te6edf3myNodeInfo Tb4b4b4} Te6edf3returns Te6edf3MutableStateFlowTb4b4b4(Tff7b72nullTb4b4b4)
Te6edf3nodeManagerTb4b4b4.Te6edf3loadCachedNodeDBTb4b4b4(Tb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3assertNullTb4b4b4(Te6edf3nodeManagerTb4b4b4.Te6edf3connectionIdentityTb4b4b4.Te6edf3valueTb4b4b4, Ta5d6ff"Ta5d6ffidentity must stay null across cache reloadTa5d6ff"Tb4b4b4)
Tb4b4b4}
Tff7b72private Tff7b72fun Td2a8ffcachedMyNodeInfoTb4b4b4(Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4) Tff7b72= Te6edf3MyNodeInfoTb4b4b4(
Te6edf3myNodeNum Tff7b72= Te6edf3myNodeNumTb4b4b4,
Te6edf3hasGPS Tff7b72= Tff7b72falseTb4b4b4,
Te6edf3model Tff7b72= Tff7b72nullTb4b4b4,
Te6edf3firmwareVersion Tff7b72= Tff7b72nullTb4b4b4,
Te6edf3couldUpdate Tff7b72= Tff7b72falseTb4b4b4,
Te6edf3shouldUpdate Tff7b72= Tff7b72falseTb4b4b4,
Te6edf3currentPacketId Tff7b72= T79c0ff0LTb4b4b4,
Te6edf3messageTimeoutMsec Tff7b72= T79c0ff0Tb4b4b4,
Te6edf3minAppVersion Tff7b72= T79c0ff0Tb4b4b4,
Te6edf3maxChannels Tff7b72= T79c0ff0Tb4b4b4,
Te6edf3hasWifi Tff7b72= Tff7b72falseTb4b4b4,
Te6edf3channelUtilization Tff7b72= T79c0ff0fTb4b4b4,
Te6edf3airUtilTx Tff7b72= T79c0ff0fTb4b4b4,
Te6edf3deviceId Tff7b72= Tff7b72nullTb4b4b4,
Tb4b4b4)
Tb4b4b4}
Served by rngit 1.5.0 - Generated in 0.08s